package com.wanglei.distributed

import scala.collection.immutable

class SubTask extends Serializable {

  var datas: Seq[Int] = _
  var logic: Int => Int = _

  def compute(): Seq[Int] = {
    datas.map(logic)
  }


}
